package com.shareyi.baseproject.kernel.common.retry;

/**
 * 重试订阅者 感应器
 * <p>
 * 因为消息被多个订阅者订阅；
 * 如果消息异常，发MQ重试后，只有处理异常的订阅者需要重新执行；
 * 已经执行成功订阅者不需要再重复执行；
 * <p>
 * 故而需要处理器实现本接口，来感知具体的订阅者名称；
 *
 * @author david
 * @date 2020-04-14
 */
public interface RetrySubscriberAware {

    /**
     * 订阅者名称
     *
     * @return
     */
    default String subscriberName() {
        return RetrySubscriberConstant.SubscriberNames.DEFAULT;
    }
}
